package com.omenkk.juc.synchronizedPlus;

import lombok.extern.slf4j.Slf4j;

@Slf4j
public class demo5 {
    public static void main(String[] args) {
        MessageQueue queue=new MessageQueue(2);
        //多个生产者线程，生产消息
for(int i=0;i<4;i++){
    Message message=new Message(i,"消息"+i);
    new Thread(()->{
        log.debug("存入消息");
        queue.put(message);
    }).start();
}

//消费者线程，消费消息
        new Thread(()->{
            while(true){
                Message take = queue.take();
                log.debug("消费消息中:{}",take);
            }
        }).start();
    }
}
